#pragma once
#include "StreamBaseType.h"
#include <queue>
#include "MediaData.h"

#define MAX_AUDIO_BUF  2000
#define MAX_VIDOE_BUF  200

class InputPin
{
public:
	InputPin(void);
	~InputPin(void);

public:
	void set_buf(std::queue<MediaData*>* buffer);
	MediaData* dequeue();
private:
	std::queue<MediaData*>* m_buffer;
	bool is_connected;	    
};

